Code Coverage for /srv/pim/src/Akeneo/Pim/Automation/RuleEngine/Component/Engine/ProductRuleApplier/ProductsSaver.php

	Code Coverage
	Classes and Traits			Functions and Methods				Lines
Total	0.00% covered (danger)	0.00%	0 / 1	33.33% covered (danger)	33.33%	1 / 3	CRAP	67.74% covered (warning)	67.74%	21 / 31
ProductsSaver	0.00% covered (danger)	0.00%	0 / 1	33.33% covered (danger)	33.33%	1 / 3	7.21	67.74% covered (warning)	67.74%	21 / 31
__construct				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	8 / 8
save				0.00% covered (danger)	0.00%	0 / 1	1.02	72.22% covered (warning)	72.22%	13 / 18
computeProductModelDescendants				0.00% covered (danger)	0.00%	0 / 1	20.00	0.00% covered (danger)	0.00%	0 / 5

1	<?php
2
3	declare(strict_types=1);
4
5	/*
6	* This file is part of the Akeneo PIM Enterprise Edition.
7	*
8	* (c) 2015 Akeneo SAS (http://www.akeneo.com)
9	*
10	* For the full copyright and license information, please view the LICENSE
11	* file that was distributed with this source code.
12	*/
13
14	namespace Akeneo\Pim\Automation\RuleEngine\Component\Engine\ProductRuleApplier;
15
16	use Akeneo\Pim\Enrichment\Component\Product\Model\EntityWithValuesInterface;
17	use Akeneo\Pim\Enrichment\Component\Product\Model\ProductInterface;
18	use Akeneo\Pim\Enrichment\Component\Product\Model\ProductModelInterface;
19	use Akeneo\Tool\Bundle\RuleEngineBundle\Model\RuleInterface;
20	use Akeneo\Tool\Bundle\VersioningBundle\Manager\VersionContext;
21	use Akeneo\Tool\Bundle\VersioningBundle\Manager\VersionManager;
22	use Akeneo\Tool\Component\StorageUtils\Cache\EntityManagerClearerInterface;
23	use Akeneo\Tool\Component\StorageUtils\Saver\BulkSaverInterface;
24	use Akeneo\Tool\Component\StorageUtils\Saver\SaverInterface;
25	use Symfony\Component\Translation\TranslatorInterface;
26
27	/**
28	* Saves products when apply a rule
29	*
30	* @author Nicolas Dupont <nicolas@akeneo.com>
31	*/
32	class ProductsSaver
33	{
34	/** @var BulkSaverInterface */
35	protected $productSaver;
36
37	/** @var BulkSaverInterface */
38	protected $productModelSaver;
39
40	/** @var VersionManager */
41	protected $versionManager;
42
43	/** @var TranslatorInterface */
44	protected $translator;
45
46	/** @var VersionContext */
47	protected $versionContext;
48
49	/** @var SaverInterface\|null */
50	private $productModelDescendantsSaver;
51
52	/** @var EntityManagerClearerInterface\|null */
53	private $cacheClearer;
54
55	/**
56	* @param BulkSaverInterface $productSaver
57	* @param BulkSaverInterface $productModelSaver
58	* @param VersionManager $versionManager
59	* @param VersionContext $versionContext
60	* @param TranslatorInterface $translator
61	* @param SaverInterface $productModelDescendantsSaver
62	* @param EntityManagerClearerInterface $cacheClearer
63	*/
64	public function __construct(
65	BulkSaverInterface $productSaver,
66	BulkSaverInterface $productModelSaver,
67	VersionManager $versionManager,
68	VersionContext $versionContext,
69	TranslatorInterface $translator,
70	SaverInterface $productModelDescendantsSaver,
71	EntityManagerClearerInterface $cacheClearer
72	) {
73	$this->productSaver = $productSaver;
74	$this->productModelSaver = $productModelSaver;
75	$this->versionManager = $versionManager;
76	$this->translator = $translator;
77	$this->versionContext = $versionContext;
78	$this->productModelDescendantsSaver = $productModelDescendantsSaver;
79	$this->cacheClearer = $cacheClearer;
80	}
81
82	/**
83	* @param RuleInterface $rule
84	* @param EntityWithValuesInterface[] $entityWithValues
85	*/
86	public function save(RuleInterface $rule, array $entityWithValues): void
87	{
88	$savingContext = $this->translator->trans(
89	'pimee_catalog_rule.product.history',
90	['%rule%' => $rule->getCode()],
91	null,
92	'en'
93	);
94	$versioningState = $this->versionManager->isRealTimeVersioning();
95	$this->versionContext->addContextInfo($savingContext, 'default');
96	$this->versionManager->setRealTimeVersioning(false);
97
98	$products = array_filter($entityWithValues, function ($item) {
99	return $item instanceof ProductInterface;
100	});
101	$productModels = array_filter($entityWithValues, function ($item) {
102	return $item instanceof ProductModelInterface;
103	});
104
105	$this->productSaver->saveAll($products);
106	$this->productModelSaver->saveAll($productModels);
107	$this->computeProductModelDescendants($productModels);
108
109	$this->versionManager->setRealTimeVersioning($versioningState);
110	$this->versionContext->unsetContextInfo('default');
111	}
112
113	/**
114	* Explicitly updates the product models descendants of a product.
115	*
116	* @param ProductModelInterface[] $productModels
117	*/
118	private function computeProductModelDescendants(array $productModels): void
119	{
120	foreach ($productModels as $productModel) {
121	if (null !== $this->productModelDescendantsSaver && null !== $this->cacheClearer) {
122	$this->productModelDescendantsSaver->save($productModel);
123	$this->cacheClearer->clear();
124	}
125	}
126	}
127	}